 Documentation
      ¶
      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.