Documentation ¶
Index ¶
- func WaitForGRPCConn()
- type ClientPort
- type EndpointRespTypePair
- type FTPEvent
- type FTPPort
- type GCStorage
- type GRPCErr
- type HTTPPort
- type HTTPRequest
- type HTTPResponse
- type MsgTypeMap
- type Opt
- type Port
- func NewFTPPort(addr, user, pass string) (*Port, error)
- func NewGCSPort() (*Port, error)
- func NewGRPCClientPort(i interface{}, target string, opts ...PortOpt) (*Port, error)
- func NewGRPCServerPort(i interface{}, port string, opts ...PortOpt) (*Port, error)
- func NewGRPCServersPort(ii []interface{}, port string, opts ...PortOpt) (*Port, error)
- func NewHTTPPort() *Port
- func NewPubsub(projectID, addr string) (*Port, error)
- type PortImpl
- type PortIn
- type PortOpt
- type PubSubSendRequest
- type Pubsub
- type SendOption
- type StorageGetRequest
- type StorageGetResponse
- type StorageInsertRequest
- type StorageInsertResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WaitForGRPCConn ¶
func WaitForGRPCConn()
Types ¶
type ClientPort ¶
type ClientPort struct {
// contains filtered or unexported fields
}
func NewGRPCClient ¶
func NewGRPCClient(i interface{}, target string, opts ...PortOpt) (*ClientPort, error)
func (*ClientPort) Close ¶
func (p *ClientPort) Close()
type EndpointRespTypePair ¶
type GCStorage ¶
type GCStorage struct {
// contains filtered or unexported fields
}
func NewGCStoragePort ¶
func NewGCStoragePort() *GCStorage
type HTTPRequest ¶
type HTTPResponse ¶
type MsgTypeMap ¶
type MsgTypeMap map[reflect.Type]EndpointRespTypePair
type Port ¶
type Port struct {
// contains filtered or unexported fields
}
func NewFTPPort ¶
func NewGCSPort ¶
func NewGRPCClientPort ¶
func NewGRPCServerPort ¶
func NewGRPCServersPort ¶
func NewHTTPPort ¶
func NewHTTPPort() *Port
type PortIn ¶
type PortIn struct {
// contains filtered or unexported fields
}
func NewGRPCServer ¶
func NewGRPCServers ¶
type PubSubSendRequest ¶
type SendOption ¶
type SendOption func(*sendOptions)
func WithCtx ¶
func WithCtx(ctx context.Context) SendOption
type StorageGetRequest ¶
type StorageGetResponse ¶
type StorageGetResponse struct {
Content []byte
}
type StorageInsertRequest ¶
type StorageInsertResponse ¶
type StorageInsertResponse struct { }
Click to show internal directories.
Click to hide internal directories.