Documentation
¶
Index ¶
- Constants
- type Client
- type ClientContext
- type ConnectType
- type WatcherAuthInterceptor
- func (i *WatcherAuthInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc
- func (i *WatcherAuthInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc
- func (i *WatcherAuthInterceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc
Constants ¶
View Source
const ClientContextKey = "client_ctx"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct { ID uuid.UUID `db:"id" json:"id"` ConnectType ConnectType `db:"connect_type" json:"connect_type"` CallbackURL pgtype.Text `db:"callback_url" json:"callback_url"` CreatedAt pgtype.Timestamp `db:"created_at" json:"created_at"` UpdatedAt pgtype.Timestamp `db:"updated_at" json:"updated_at"` }
type ClientContext ¶
type ClientContext struct {
Client *Client
}
type ConnectType ¶
type ConnectType string
const ( ConnectTypeGRPC ConnectType = "grpc" ConnectTypeRest ConnectType = "rest" )
func (ConnectType) IsValid ¶
func (ct ConnectType) IsValid() bool
type WatcherAuthInterceptor ¶
type WatcherAuthInterceptor struct {
// contains filtered or unexported fields
}
func NewWatcherAuthInterceptor ¶
func NewWatcherAuthInterceptor( clientID, clientSecret string, ) *WatcherAuthInterceptor
func (*WatcherAuthInterceptor) WrapStreamingClient ¶
func (i *WatcherAuthInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc
WrapStreamingClient wraps the streaming server function
func (*WatcherAuthInterceptor) WrapStreamingHandler ¶
func (i *WatcherAuthInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc
WrapStreamingHandler wraps the streaming server function
Click to show internal directories.
Click to hide internal directories.