port

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

type EndpointRespTypePair struct {
	RespType reflect.Type
	Endpoint string
}

type FTPEvent struct {
	Path    string
	Payload []byte
}

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

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

type GRPCErr struct {
	Err error
}

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

type HTTPRequest struct {
	Body []byte
	//URL    *url.URL
	Method string
	Host   string
	URL    string
}

type HTTPResponse struct {
	Body   []byte
	Status int
}

type MsgTypeMap map[reflect.Type]EndpointRespTypePair

type Opt func(*portOpts)

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

type PortImpl interface {
	Send(ctx context.Context, msg interface{}) error
	Receive(ctx context.Context) (interface{}, error)
}

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

type PortOpt func(*portOpts)

type PubSubSendRequest struct {
	Topic   string
	Message proto.Message
}

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

type SendOption func(*sendOptions)

type StorageGetRequest struct {
	Bucket string
	Object string
}

type StorageGetResponse struct {
	Content []byte
}

type StorageInsertRequest struct {
	Bucket  string
	Object  string
	Content []byte
}

type StorageInsertResponse struct {
}