client

package
v0.0.0-...-5a969d9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 7, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildEchoerFunc 

func BuildEchoerFunc(grpccli chatterpb.ChatterClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc

BuildEchoerFunc builds the remote method to invoke for "chatter" service "echoer" endpoint.

func BuildEchoerPayload 

func BuildEchoerPayload(chatterEchoerToken string) (*chatter.EchoerPayload, error)

BuildEchoerPayload builds the payload for the chatter echoer endpoint from CLI flags.

func BuildHistoryFunc 

func BuildHistoryFunc(grpccli chatterpb.ChatterClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc

BuildHistoryFunc builds the remote method to invoke for "chatter" service "history" endpoint.

func BuildHistoryPayload 

func BuildHistoryPayload(chatterHistoryView string, chatterHistoryToken string) (*chatter.HistoryPayload, error)

BuildHistoryPayload builds the payload for the chatter history endpoint from CLI flags.

func BuildListenerFunc 

func BuildListenerFunc(grpccli chatterpb.ChatterClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc

BuildListenerFunc builds the remote method to invoke for "chatter" service "listener" endpoint.

func BuildListenerPayload 

func BuildListenerPayload(chatterListenerToken string) (*chatter.ListenerPayload, error)

BuildListenerPayload builds the payload for the chatter listener endpoint from CLI flags.

func BuildLoginFunc 

func BuildLoginFunc(grpccli chatterpb.ChatterClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc

BuildLoginFunc builds the remote method to invoke for "chatter" service "login" endpoint.

func BuildLoginPayload 

func BuildLoginPayload(chatterLoginUser string, chatterLoginPassword string) (*chatter.LoginPayload, error)

BuildLoginPayload builds the payload for the chatter login endpoint from CLI flags.

func BuildSubscribeFunc 

func BuildSubscribeFunc(grpccli chatterpb.ChatterClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc

BuildSubscribeFunc builds the remote method to invoke for "chatter" service "subscribe" endpoint.

func BuildSubscribePayload 

func BuildSubscribePayload(chatterSubscribeToken string) (*chatter.SubscribePayload, error)

BuildSubscribePayload builds the payload for the chatter subscribe endpoint from CLI flags.

func BuildSummaryFunc 

func BuildSummaryFunc(grpccli chatterpb.ChatterClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc

BuildSummaryFunc builds the remote method to invoke for "chatter" service "summary" endpoint.

func BuildSummaryPayload 

func BuildSummaryPayload(chatterSummaryToken string) (*chatter.SummaryPayload, error)

BuildSummaryPayload builds the payload for the chatter summary endpoint from CLI flags.

func DecodeEchoerResponse 

func DecodeEchoerResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)

DecodeEchoerResponse decodes responses from the chatter echoer endpoint.

func DecodeHistoryResponse 

func DecodeHistoryResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)

DecodeHistoryResponse decodes responses from the chatter history endpoint.

func DecodeListenerResponse 

func DecodeListenerResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)

DecodeListenerResponse decodes responses from the chatter listener endpoint.

func DecodeLoginResponse 

func DecodeLoginResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)

DecodeLoginResponse decodes responses from the chatter login endpoint.

func DecodeSubscribeResponse 

func DecodeSubscribeResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)

DecodeSubscribeResponse decodes responses from the chatter subscribe endpoint.

func DecodeSummaryResponse 

func DecodeSummaryResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)

DecodeSummaryResponse decodes responses from the chatter summary endpoint.

func EncodeEchoerRequest 

func EncodeEchoerRequest(ctx context.Context, v any, md *metadata.MD) (any, error)

EncodeEchoerRequest encodes requests sent to chatter echoer endpoint.

func EncodeHistoryRequest 

func EncodeHistoryRequest(ctx context.Context, v any, md *metadata.MD) (any, error)

EncodeHistoryRequest encodes requests sent to chatter history endpoint.

func EncodeListenerRequest 

func EncodeListenerRequest(ctx context.Context, v any, md *metadata.MD) (any, error)

EncodeListenerRequest encodes requests sent to chatter listener endpoint.

func EncodeLoginRequest 

func EncodeLoginRequest(ctx context.Context, v any, md *metadata.MD) (any, error)

EncodeLoginRequest encodes requests sent to chatter login endpoint.

func EncodeSubscribeRequest 

func EncodeSubscribeRequest(ctx context.Context, v any, md *metadata.MD) (any, error)

EncodeSubscribeRequest encodes requests sent to chatter subscribe endpoint.

func EncodeSummaryRequest 

func EncodeSummaryRequest(ctx context.Context, v any, md *metadata.MD) (any, error)

EncodeSummaryRequest encodes requests sent to chatter summary endpoint.

func NewChatSummaryCollectionChatSummaryCollection 

func NewChatSummaryCollectionChatSummaryCollection(v *chatterpb.ChatSummaryCollection) chatterviews.ChatSummaryCollectionView

func NewEchoerResponseEchoerResponse 

func NewEchoerResponseEchoerResponse(v *chatterpb.EchoerResponse) string

func NewHistoryResponseChatSummaryView 

func NewHistoryResponseChatSummaryView(v *chatterpb.HistoryResponse) *chatterviews.ChatSummaryView

func NewLoginResult 

func NewLoginResult(message *chatterpb.LoginResponse) string

NewLoginResult builds the result type of the "login" endpoint of the "chatter" service from the gRPC response type.

func NewProtoEchoerStreamingRequest 

func NewProtoEchoerStreamingRequest(spayload string) *chatterpb.EchoerStreamingRequest

func NewProtoHistoryRequest 

func NewProtoHistoryRequest() *chatterpb.HistoryRequest

NewProtoHistoryRequest builds the gRPC request type from the payload of the "history" endpoint of the "chatter" service.

func NewProtoListenerStreamingRequest 

func NewProtoListenerStreamingRequest(spayload string) *chatterpb.ListenerStreamingRequest

func NewProtoLoginRequest 

func NewProtoLoginRequest() *chatterpb.LoginRequest

NewProtoLoginRequest builds the gRPC request type from the payload of the "login" endpoint of the "chatter" service.

func NewProtoSubscribeRequest 

func NewProtoSubscribeRequest() *chatterpb.SubscribeRequest

NewProtoSubscribeRequest builds the gRPC request type from the payload of the "subscribe" endpoint of the "chatter" service.

func NewProtoSummaryStreamingRequest 

func NewProtoSummaryStreamingRequest(spayload string) *chatterpb.SummaryStreamingRequest

func NewSubscribeResponseEvent 

func NewSubscribeResponseEvent(v *chatterpb.SubscribeResponse) *chatter.Event

func ValidateChatSummary 

func ValidateChatSummary(elem *chatterpb.ChatSummary) (err error)

ValidateChatSummary runs the validations defined on ChatSummary.

func ValidateChatSummaryCollection 

func ValidateChatSummaryCollection(stream *chatterpb.ChatSummaryCollection) (err error)

ValidateChatSummaryCollection runs the validations defined on ChatSummaryCollection.

func ValidateHistoryResponse 

func ValidateHistoryResponse(stream *chatterpb.HistoryResponse) (err error)

ValidateHistoryResponse runs the validations defined on HistoryResponse.

func ValidateSubscribeResponse 

func ValidateSubscribeResponse(stream *chatterpb.SubscribeResponse) (err error)

ValidateSubscribeResponse runs the validations defined on SubscribeResponse.

Types

type Client 

type Client struct {
	// contains filtered or unexported fields
}

Client lists the service endpoint gRPC clients.

func NewClient 

func NewClient(cc *grpc.ClientConn, opts ...grpc.CallOption) *Client

NewClient instantiates gRPC client for all the chatter service servers.

func (*Client) Echoer 

func (c *Client) Echoer() goa.Endpoint

Echoer calls the "Echoer" function in chatterpb.ChatterClient interface.

func (*Client) History 

func (c *Client) History() goa.Endpoint

History calls the "History" function in chatterpb.ChatterClient interface.

func (*Client) Listener 

func (c *Client) Listener() goa.Endpoint

Listener calls the "Listener" function in chatterpb.ChatterClient interface.

func (*Client) Login 

func (c *Client) Login() goa.Endpoint

Login calls the "Login" function in chatterpb.ChatterClient interface.

func (*Client) Subscribe 

func (c *Client) Subscribe() goa.Endpoint

Subscribe calls the "Subscribe" function in chatterpb.ChatterClient interface.

func (*Client) Summary 

func (c *Client) Summary() goa.Endpoint

Summary calls the "Summary" function in chatterpb.ChatterClient interface.

type EchoerClientStream 

type EchoerClientStream struct {
	// contains filtered or unexported fields
}

EchoerClientStream implements the chatter.EchoerClientStream interface.

func (*EchoerClientStream) Close 

func (s *EchoerClientStream) Close() error

func (*EchoerClientStream) Recv 

func (s *EchoerClientStream) Recv() (string, error)

Recv reads instances of "chatterpb.EchoerResponse" from the "echoer" endpoint gRPC stream.

func (*EchoerClientStream) Send 

func (s *EchoerClientStream) Send(res string) error

Send streams instances of "chatterpb.EchoerStreamingRequest" to the "echoer" endpoint gRPC stream.

type HistoryClientStream 

type HistoryClientStream struct {
	// contains filtered or unexported fields
}

HistoryClientStream implements the chatter.HistoryClientStream interface.

func (*HistoryClientStream) Recv 

func (s *HistoryClientStream) Recv() (*chatter.ChatSummary, error)

Recv reads instances of "chatterpb.HistoryResponse" from the "history" endpoint gRPC stream.

func (*HistoryClientStream) SetView 

func (s *HistoryClientStream) SetView(view string)

SetView sets the view.

type ListenerClientStream 

type ListenerClientStream struct {
	// contains filtered or unexported fields
}

ListenerClientStream implements the chatter.ListenerClientStream interface.

func (*ListenerClientStream) Close 

func (s *ListenerClientStream) Close() error

func (*ListenerClientStream) Send 

func (s *ListenerClientStream) Send(res string) error

Send streams instances of "chatterpb.ListenerStreamingRequest" to the "listener" endpoint gRPC stream.

type SubscribeClientStream 

type SubscribeClientStream struct {
	// contains filtered or unexported fields
}

SubscribeClientStream implements the chatter.SubscribeClientStream interface.

func (*SubscribeClientStream) Recv 

func (s *SubscribeClientStream) Recv() (*chatter.Event, error)

Recv reads instances of "chatterpb.SubscribeResponse" from the "subscribe" endpoint gRPC stream.

type SummaryClientStream 

type SummaryClientStream struct {
	// contains filtered or unexported fields
}

SummaryClientStream implements the chatter.SummaryClientStream interface.

func (*SummaryClientStream) CloseAndRecv 

func (s *SummaryClientStream) CloseAndRecv() (chatter.ChatSummaryCollection, error)

CloseAndRecv reads instances of "chatterpb.ChatSummaryCollection" from the "summary" endpoint gRPC stream.

func (*SummaryClientStream) Send 

func (s *SummaryClientStream) Send(res string) error

Send streams instances of "chatterpb.SummaryStreamingRequest" to the "summary" endpoint gRPC stream.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.