v1

type ConfigRequest struct {
	BatchInterval int32 `protobuf:"varint,1,opt,name=batchInterval,proto3" json:"batchInterval,omitempty"`
	BatchSize     int32 `protobuf:"varint,2,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	// Ability to disable listener type
	ListenerType []ListenerType `protobuf:"varint,3,rep,packed,name=listenerType,proto3,enum=relay.config.v1.ListenerType" json:"listenerType,omitempty"`
	// contains filtered or unexported fields
}

type ConfigResponse struct {
	Success   bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Identifer string `protobuf:"bytes,2,opt,name=identifer,proto3" json:"identifer,omitempty"`
	// contains filtered or unexported fields
}

type Listener struct {
	ListenerType ListenerType `protobuf:"varint,1,opt,name=listenerType,proto3,enum=relay.config.v1.ListenerType" json:"listenerType,omitempty"`
	Active       bool         `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"`
	// contains filtered or unexported fields
}

type ListenerType int32

type RelayClient interface {
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
	Config(ctx context.Context, in *ConfigRequest, opts ...grpc.CallOption) (*ConfigResponse, error)
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

type RelayServer interface {
	Start(context.Context, *StartRequest) (*StartResponse, error)
	Stop(context.Context, *StopRequest) (*StopResponse, error)
	Config(context.Context, *ConfigRequest) (*ConfigResponse, error)
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// contains filtered or unexported methods
}

type StartRequest struct {
	Config *ConfigRequest `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type StartResponse struct {
	Status *StatusResponse `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

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

type StatusResponse struct {
	Processed    int32                  `protobuf:"varint,1,opt,name=processed,proto3" json:"processed,omitempty"`
	CurrentSize  int32                  `protobuf:"varint,2,opt,name=currentSize,proto3" json:"currentSize,omitempty"`
	Failed       int32                  `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"`
	ListenerType []*Listener            `protobuf:"bytes,4,rep,name=listenerType,proto3" json:"listenerType,omitempty"`
	Running      bool                   `protobuf:"varint,9,opt,name=running,proto3" json:"running,omitempty"`
	LastSent     *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=lastSent,proto3" json:"lastSent,omitempty"`
	StartedAt    *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=startedAt,proto3" json:"startedAt,omitempty"`
	// contains filtered or unexported fields
}

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

type StopResponse struct {
	Status *StatusResponse `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedRelayServer struct {
}

type UnsafeRelayServer interface {
	// contains filtered or unexported methods
}