mirror of https://github.com/dapr/docs.git
Merge branch 'v1.1' into aacrawfi/integrations
This commit is contained in:
commit
596160ad4b
|
@ -86,7 +86,7 @@ data := []byte("ping")
|
|||
// create the client
|
||||
client, err := dapr.NewClient()
|
||||
if err != nil {
|
||||
logger.Panic(err)
|
||||
log.Panic(err)
|
||||
}
|
||||
defer client.Close()
|
||||
```
|
||||
|
@ -95,11 +95,11 @@ defer client.Close()
|
|||
|
||||
```go
|
||||
// save state with the key key1
|
||||
err = client.SaveStateData(ctx, "statestore", "key1", "1", data)
|
||||
err = client.SaveState(ctx, "statestore", "key1", data)
|
||||
if err != nil {
|
||||
logger.Panic(err)
|
||||
log.Panic(err)
|
||||
}
|
||||
logger.Println("data saved")
|
||||
log.Println("data saved")
|
||||
```
|
||||
|
||||
Hooray!
|
||||
|
@ -135,6 +135,7 @@ import (
|
|||
```go
|
||||
// server is our user app
|
||||
type server struct {
|
||||
pb.UnimplementedAppCallbackServer
|
||||
}
|
||||
|
||||
// EchoMethod is a simple demo method to invoke
|
||||
|
@ -183,9 +184,9 @@ func (s *server) OnBindingEvent(ctx context.Context, in *pb.BindingEventRequest)
|
|||
}
|
||||
|
||||
// This method is fired whenever a message has been published to a topic that has been subscribed. Dapr sends published messages in a CloudEvents 0.3 envelope.
|
||||
func (s *server) OnTopicEvent(ctx context.Context, in *pb.TopicEventRequest) (*empty.Empty, error) {
|
||||
func (s *server) OnTopicEvent(ctx context.Context, in *pb.TopicEventRequest) (*pb.TopicEventResponse, error) {
|
||||
fmt.Println("Topic message arrived")
|
||||
return &empty.Empty{}, nil
|
||||
return &pb.TopicEventResponse{}, nil
|
||||
}
|
||||
|
||||
```
|
||||
|
|
|
@ -91,7 +91,7 @@ The most common cause of this failure is that a component (such as a state store
|
|||
|
||||
To diagnose the root cause:
|
||||
|
||||
- Significantly increase the liveness probe delay - [link]({{< ref "kubernetes-overview.md" >}})
|
||||
- Significantly increase the liveness probe delay - [link]({{< ref "kubernetes-annotations.md" >}})
|
||||
- Set the log level of the sidecar to debug - [link]({{< ref "logs-troubleshooting.md#setting-the-sidecar-log-level" >}})
|
||||
- Watch the logs for meaningful information - [link]({{< ref "logs-troubleshooting.md#viewing-logs-on-kubernetes" >}})
|
||||
|
||||
|
|
Loading…
Reference in New Issue