core

package
v0.0.0-...-ed0dbbb Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 1, 2024 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CampaignService_CreateCampaign_FullMethodName        = "/core.CampaignService/CreateCampaign"
	CampaignService_StartCampaign_FullMethodName         = "/core.CampaignService/StartCampaign"
	CampaignService_GetCampaign_FullMethodName           = "/core.CampaignService/GetCampaign"
	CampaignService_ListCampaigns_FullMethodName         = "/core.CampaignService/ListCampaigns"
	CampaignService_RunBacktestByCampaign_FullMethodName = "/core.CampaignService/RunBacktestByCampaign"
)

Variables

View Source 
var CampaignService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "core.CampaignService",
	HandlerType: (*CampaignServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateCampaign",
			Handler:    _CampaignService_CreateCampaign_Handler,
		},
		{
			MethodName: "StartCampaign",
			Handler:    _CampaignService_StartCampaign_Handler,
		},
		{
			MethodName: "GetCampaign",
			Handler:    _CampaignService_GetCampaign_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListCampaigns",
			Handler:       _CampaignService_ListCampaigns_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "RunBacktestByCampaign",
			Handler:       _CampaignService_RunBacktestByCampaign_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/core/campaign.proto",
}

CampaignService_ServiceDesc is the grpc.ServiceDesc for CampaignService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_proto_core_campaign_proto protoreflect.FileDescriptor

Functions

func RegisterCampaignServiceServer 

func RegisterCampaignServiceServer(s grpc.ServiceRegistrar, srv CampaignServiceServer)

Types

type AddTasksForCampaignRequest 

type AddTasksForCampaignRequest struct {
	CampaignId string        `protobuf:"bytes,1,opt,name=campaign_id,json=campaignId,proto3" json:"campaign_id,omitempty"`
	Tasks      []*model.Task `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

AddTasksForCampaignRequest is the request for add tasks for campaign

func (*AddTasksForCampaignRequest) Descriptor deprecated 

func (*AddTasksForCampaignRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddTasksForCampaignRequest.ProtoReflect.Descriptor instead.

func (*AddTasksForCampaignRequest) GetCampaignId 

func (x *AddTasksForCampaignRequest) GetCampaignId() string

func (*AddTasksForCampaignRequest) GetTasks 

func (x *AddTasksForCampaignRequest) GetTasks() []*model.Task

func (*AddTasksForCampaignRequest) ProtoMessage 

func (*AddTasksForCampaignRequest) ProtoMessage()

func (*AddTasksForCampaignRequest) ProtoReflect 

func (x *AddTasksForCampaignRequest) ProtoReflect() protoreflect.Message

func (*AddTasksForCampaignRequest) Reset 

func (x *AddTasksForCampaignRequest) Reset()

func (*AddTasksForCampaignRequest) String 

func (x *AddTasksForCampaignRequest) String() string

type AddTasksForCampaignResponse 

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

AddTasksForCampaignResponse is the response for add tasks for campaign

func (*AddTasksForCampaignResponse) Descriptor deprecated 

func (*AddTasksForCampaignResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddTasksForCampaignResponse.ProtoReflect.Descriptor instead.

func (*AddTasksForCampaignResponse) ProtoMessage 

func (*AddTasksForCampaignResponse) ProtoMessage()

func (*AddTasksForCampaignResponse) ProtoReflect 

func (x *AddTasksForCampaignResponse) ProtoReflect() protoreflect.Message

func (*AddTasksForCampaignResponse) Reset 

func (x *AddTasksForCampaignResponse) Reset()

func (*AddTasksForCampaignResponse) String 

func (x *AddTasksForCampaignResponse) String() string

type BacktestResultResponse 

type BacktestResultResponse struct {
	Reward *model.Reward `protobuf:"bytes,1,opt,name=reward,proto3" json:"reward,omitempty"`
	// contains filtered or unexported fields
}

BacktestResultResponse is the response for backtest result

func (*BacktestResultResponse) Descriptor deprecated 

func (*BacktestResultResponse) Descriptor() ([]byte, []int)

Deprecated: Use BacktestResultResponse.ProtoReflect.Descriptor instead.

func (*BacktestResultResponse) GetReward 

func (x *BacktestResultResponse) GetReward() *model.Reward

func (*BacktestResultResponse) ProtoMessage 

func (*BacktestResultResponse) ProtoMessage()

func (*BacktestResultResponse) ProtoReflect 

func (x *BacktestResultResponse) ProtoReflect() protoreflect.Message

func (*BacktestResultResponse) Reset 

func (x *BacktestResultResponse) Reset()

func (*BacktestResultResponse) String 

func (x *BacktestResultResponse) String() string

type CampaignServiceClient 

type CampaignServiceClient interface {
	CreateCampaign(ctx context.Context, in *CreateCampaignRequest, opts ...grpc.CallOption) (*CreateCampaignResponse, error)
	StartCampaign(ctx context.Context, in *StartCampaignRequest, opts ...grpc.CallOption) (*StartCampaignResponse, error)
	GetCampaign(ctx context.Context, in *GetCampaignRequest, opts ...grpc.CallOption) (*GetCampaignResponse, error)
	ListCampaigns(ctx context.Context, in *ListCampaignsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetCampaignResponse], error)
	RunBacktestByCampaign(ctx context.Context, in *GetCampaignRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[BacktestResultResponse], error)
}

CampaignServiceClient is the client API for CampaignService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

CampaignService is the service for campaign

func NewCampaignServiceClient 

func NewCampaignServiceClient(cc grpc.ClientConnInterface) CampaignServiceClient

type CampaignServiceServer 

type CampaignServiceServer interface {
	CreateCampaign(context.Context, *CreateCampaignRequest) (*CreateCampaignResponse, error)
	StartCampaign(context.Context, *StartCampaignRequest) (*StartCampaignResponse, error)
	GetCampaign(context.Context, *GetCampaignRequest) (*GetCampaignResponse, error)
	ListCampaigns(*ListCampaignsRequest, grpc.ServerStreamingServer[GetCampaignResponse]) error
	RunBacktestByCampaign(*GetCampaignRequest, grpc.ServerStreamingServer[BacktestResultResponse]) error
}

CampaignServiceServer is the server API for CampaignService service. All implementations should embed UnimplementedCampaignServiceServer for forward compatibility.

CampaignService is the service for campaign

type CampaignService_ListCampaignsClient 

type CampaignService_ListCampaignsClient = grpc.ServerStreamingClient[GetCampaignResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type CampaignService_ListCampaignsServer 

type CampaignService_ListCampaignsServer = grpc.ServerStreamingServer[GetCampaignResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type CampaignService_RunBacktestByCampaignClient 

type CampaignService_RunBacktestByCampaignClient = grpc.ServerStreamingClient[BacktestResultResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type CampaignService_RunBacktestByCampaignServer 

type CampaignService_RunBacktestByCampaignServer = grpc.ServerStreamingServer[BacktestResultResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type CreateCampaignRequest 

type CreateCampaignRequest struct {
	Name       string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	StartTime  *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	Mode       model.CampaignMode     `protobuf:"varint,3,opt,name=mode,proto3,enum=entity.domain.core.model.CampaignMode" json:"mode,omitempty"`
	TargetPool string                 `protobuf:"bytes,4,opt,name=target_pool,json=targetPool,proto3" json:"target_pool,omitempty"`
	MinAmount  float64                `protobuf:"fixed64,5,opt,name=min_amount,json=minAmount,proto3" json:"min_amount,omitempty"`
	// contains filtered or unexported fields
}

CreateCampaignRequest is the request for create campaign

func (*CreateCampaignRequest) Descriptor deprecated 

func (*CreateCampaignRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateCampaignRequest.ProtoReflect.Descriptor instead.

func (*CreateCampaignRequest) GetMinAmount 

func (x *CreateCampaignRequest) GetMinAmount() float64

func (*CreateCampaignRequest) GetMode 

func (x *CreateCampaignRequest) GetMode() model.CampaignMode

func (*CreateCampaignRequest) GetName 

func (x *CreateCampaignRequest) GetName() string

func (*CreateCampaignRequest) GetStartTime 

func (x *CreateCampaignRequest) GetStartTime() *timestamppb.Timestamp

func (*CreateCampaignRequest) GetTargetPool 

func (x *CreateCampaignRequest) GetTargetPool() string

func (*CreateCampaignRequest) ProtoMessage 

func (*CreateCampaignRequest) ProtoMessage()

func (*CreateCampaignRequest) ProtoReflect 

func (x *CreateCampaignRequest) ProtoReflect() protoreflect.Message

func (*CreateCampaignRequest) Reset 

func (x *CreateCampaignRequest) Reset()

func (*CreateCampaignRequest) String 

func (x *CreateCampaignRequest) String() string

type CreateCampaignResponse 

type CreateCampaignResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

CreateCampaignResponse is the response for create campaign

func (*CreateCampaignResponse) Descriptor deprecated 

func (*CreateCampaignResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateCampaignResponse.ProtoReflect.Descriptor instead.

func (*CreateCampaignResponse) GetId 

func (x *CreateCampaignResponse) GetId() string

func (*CreateCampaignResponse) ProtoMessage 

func (*CreateCampaignResponse) ProtoMessage()

func (*CreateCampaignResponse) ProtoReflect 

func (x *CreateCampaignResponse) ProtoReflect() protoreflect.Message

func (*CreateCampaignResponse) Reset 

func (x *CreateCampaignResponse) Reset()

func (*CreateCampaignResponse) String 

func (x *CreateCampaignResponse) String() string

type GetCampaignRequest 

type GetCampaignRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetCampaignRequest is the request for get campaign

func (*GetCampaignRequest) Descriptor deprecated 

func (*GetCampaignRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetCampaignRequest.ProtoReflect.Descriptor instead.

func (*GetCampaignRequest) GetId 

func (x *GetCampaignRequest) GetId() string

func (*GetCampaignRequest) ProtoMessage 

func (*GetCampaignRequest) ProtoMessage()

func (*GetCampaignRequest) ProtoReflect 

func (x *GetCampaignRequest) ProtoReflect() protoreflect.Message

func (*GetCampaignRequest) Reset 

func (x *GetCampaignRequest) Reset()

func (*GetCampaignRequest) String 

func (x *GetCampaignRequest) String() string

type GetCampaignResponse 

type GetCampaignResponse struct {
	Campaign *model.Campaign `protobuf:"bytes,1,opt,name=campaign,proto3" json:"campaign,omitempty"`
	Tasks    []*model.Task   `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

GetCampaignResponse is the response for get campaign

func (*GetCampaignResponse) Descriptor deprecated 

func (*GetCampaignResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetCampaignResponse.ProtoReflect.Descriptor instead.

func (*GetCampaignResponse) GetCampaign 

func (x *GetCampaignResponse) GetCampaign() *model.Campaign

func (*GetCampaignResponse) GetTasks 

func (x *GetCampaignResponse) GetTasks() []*model.Task

func (*GetCampaignResponse) ProtoMessage 

func (*GetCampaignResponse) ProtoMessage()

func (*GetCampaignResponse) ProtoReflect 

func (x *GetCampaignResponse) ProtoReflect() protoreflect.Message

func (*GetCampaignResponse) Reset 

func (x *GetCampaignResponse) Reset()

func (*GetCampaignResponse) String 

func (x *GetCampaignResponse) String() string

type ListCampaignsRequest 

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

ListCampaignsRequest is the request for list campaigns

func (*ListCampaignsRequest) Descriptor deprecated 

func (*ListCampaignsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListCampaignsRequest.ProtoReflect.Descriptor instead.

func (*ListCampaignsRequest) ProtoMessage 

func (*ListCampaignsRequest) ProtoMessage()

func (*ListCampaignsRequest) ProtoReflect 

func (x *ListCampaignsRequest) ProtoReflect() protoreflect.Message

func (*ListCampaignsRequest) Reset 

func (x *ListCampaignsRequest) Reset()

func (*ListCampaignsRequest) String 

func (x *ListCampaignsRequest) String() string

type MockCampaignServiceClient 

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

MockCampaignServiceClient is a mock of CampaignServiceClient interface.

func NewMockCampaignServiceClient 

func NewMockCampaignServiceClient(ctrl *gomock.Controller) *MockCampaignServiceClient

NewMockCampaignServiceClient creates a new mock instance.

func (*MockCampaignServiceClient) CreateCampaign 

func (m *MockCampaignServiceClient) CreateCampaign(ctx context.Context, in *CreateCampaignRequest, opts ...grpc.CallOption) (*CreateCampaignResponse, error)

CreateCampaign mocks base method.

func (*MockCampaignServiceClient) EXPECT 

func (m *MockCampaignServiceClient) EXPECT() *MockCampaignServiceClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCampaignServiceClient) GetCampaign 

func (m *MockCampaignServiceClient) GetCampaign(ctx context.Context, in *GetCampaignRequest, opts ...grpc.CallOption) (*GetCampaignResponse, error)

GetCampaign mocks base method.

func (*MockCampaignServiceClient) ListCampaigns 

func (m *MockCampaignServiceClient) ListCampaigns(ctx context.Context, in *ListCampaignsRequest, opts ...grpc.CallOption) (CampaignService_ListCampaignsClient, error)

ListCampaigns mocks base method.

func (*MockCampaignServiceClient) RunBacktestByCampaign 

func (m *MockCampaignServiceClient) RunBacktestByCampaign(ctx context.Context, in *GetCampaignRequest, opts ...grpc.CallOption) (CampaignService_RunBacktestByCampaignClient, error)

RunBacktestByCampaign mocks base method.

func (*MockCampaignServiceClient) StartCampaign 

func (m *MockCampaignServiceClient) StartCampaign(ctx context.Context, in *StartCampaignRequest, opts ...grpc.CallOption) (*StartCampaignResponse, error)

StartCampaign mocks base method.

type MockCampaignServiceClientMockRecorder 

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

MockCampaignServiceClientMockRecorder is the mock recorder for MockCampaignServiceClient.

func (*MockCampaignServiceClientMockRecorder) CreateCampaign 

func (mr *MockCampaignServiceClientMockRecorder) CreateCampaign(ctx, in interface{}, opts ...interface{}) *gomock.Call

CreateCampaign indicates an expected call of CreateCampaign.

func (*MockCampaignServiceClientMockRecorder) GetCampaign 

func (mr *MockCampaignServiceClientMockRecorder) GetCampaign(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetCampaign indicates an expected call of GetCampaign.

func (*MockCampaignServiceClientMockRecorder) ListCampaigns 

func (mr *MockCampaignServiceClientMockRecorder) ListCampaigns(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListCampaigns indicates an expected call of ListCampaigns.

func (*MockCampaignServiceClientMockRecorder) RunBacktestByCampaign 

func (mr *MockCampaignServiceClientMockRecorder) RunBacktestByCampaign(ctx, in interface{}, opts ...interface{}) *gomock.Call

RunBacktestByCampaign indicates an expected call of RunBacktestByCampaign.

func (*MockCampaignServiceClientMockRecorder) StartCampaign 

func (mr *MockCampaignServiceClientMockRecorder) StartCampaign(ctx, in interface{}, opts ...interface{}) *gomock.Call

StartCampaign indicates an expected call of StartCampaign.

type MockCampaignServiceServer 

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

MockCampaignServiceServer is a mock of CampaignServiceServer interface.

func NewMockCampaignServiceServer 

func NewMockCampaignServiceServer(ctrl *gomock.Controller) *MockCampaignServiceServer

NewMockCampaignServiceServer creates a new mock instance.

func (*MockCampaignServiceServer) CreateCampaign 

func (m *MockCampaignServiceServer) CreateCampaign(ctx context.Context, in *CreateCampaignRequest) (*CreateCampaignResponse, error)

CreateCampaign mocks base method.

func (*MockCampaignServiceServer) EXPECT 

func (m *MockCampaignServiceServer) EXPECT() *MockCampaignServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCampaignServiceServer) GetCampaign 

func (m *MockCampaignServiceServer) GetCampaign(ctx context.Context, in *GetCampaignRequest) (*GetCampaignResponse, error)

GetCampaign mocks base method.

func (*MockCampaignServiceServer) ListCampaigns 

func (m *MockCampaignServiceServer) ListCampaigns(blob *ListCampaignsRequest, server CampaignService_ListCampaignsServer) error

ListCampaigns mocks base method.

func (*MockCampaignServiceServer) RunBacktestByCampaign 

func (m *MockCampaignServiceServer) RunBacktestByCampaign(blob *GetCampaignRequest, server CampaignService_RunBacktestByCampaignServer) error

RunBacktestByCampaign mocks base method.

func (*MockCampaignServiceServer) StartCampaign 

func (m *MockCampaignServiceServer) StartCampaign(ctx context.Context, in *StartCampaignRequest) (*StartCampaignResponse, error)

StartCampaign mocks base method.

type MockCampaignServiceServerMockRecorder 

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

MockCampaignServiceServerMockRecorder is the mock recorder for MockCampaignServiceServer.

func (*MockCampaignServiceServerMockRecorder) CreateCampaign 

func (mr *MockCampaignServiceServerMockRecorder) CreateCampaign(ctx, in interface{}) *gomock.Call

CreateCampaign indicates an expected call of CreateCampaign.

func (*MockCampaignServiceServerMockRecorder) GetCampaign 

func (mr *MockCampaignServiceServerMockRecorder) GetCampaign(ctx, in interface{}) *gomock.Call

GetCampaign indicates an expected call of GetCampaign.

func (*MockCampaignServiceServerMockRecorder) ListCampaigns 

func (mr *MockCampaignServiceServerMockRecorder) ListCampaigns(blob, server interface{}) *gomock.Call

ListCampaigns indicates an expected call of ListCampaigns.

func (*MockCampaignServiceServerMockRecorder) RunBacktestByCampaign 

func (mr *MockCampaignServiceServerMockRecorder) RunBacktestByCampaign(blob, server interface{}) *gomock.Call

RunBacktestByCampaign indicates an expected call of RunBacktestByCampaign.

func (*MockCampaignServiceServerMockRecorder) StartCampaign 

func (mr *MockCampaignServiceServerMockRecorder) StartCampaign(ctx, in interface{}) *gomock.Call

StartCampaign indicates an expected call of StartCampaign.

type MockCampaignService_ListCampaignsClient 

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

MockCampaignService_ListCampaignsClient is a mock of CampaignService_ListCampaignsClient interface.

func NewMockCampaignService_ListCampaignsClient 

func NewMockCampaignService_ListCampaignsClient(ctrl *gomock.Controller) *MockCampaignService_ListCampaignsClient

NewMockCampaignService_ListCampaignsClient creates a new mock instance.

func (*MockCampaignService_ListCampaignsClient) CloseSend 

func (m *MockCampaignService_ListCampaignsClient) CloseSend() error

CloseSend mocks base method.

func (*MockCampaignService_ListCampaignsClient) Context 

func (m *MockCampaignService_ListCampaignsClient) Context() context.Context

Context mocks base method.

func (*MockCampaignService_ListCampaignsClient) EXPECT 

func (m *MockCampaignService_ListCampaignsClient) EXPECT() *MockCampaignService_ListCampaignsClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCampaignService_ListCampaignsClient) Header 

func (m *MockCampaignService_ListCampaignsClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockCampaignService_ListCampaignsClient) Recv 

func (m *MockCampaignService_ListCampaignsClient) Recv() (*GetCampaignResponse, error)

Recv mocks base method.

func (*MockCampaignService_ListCampaignsClient) RecvMsg 

func (m *MockCampaignService_ListCampaignsClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockCampaignService_ListCampaignsClient) SendMsg 

func (m *MockCampaignService_ListCampaignsClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockCampaignService_ListCampaignsClient) Trailer 

func (m *MockCampaignService_ListCampaignsClient) Trailer() metadata.MD

Trailer mocks base method.

type MockCampaignService_ListCampaignsClientMockRecorder 

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

MockCampaignService_ListCampaignsClientMockRecorder is the mock recorder for MockCampaignService_ListCampaignsClient.

func (*MockCampaignService_ListCampaignsClientMockRecorder) CloseSend 

func (mr *MockCampaignService_ListCampaignsClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockCampaignService_ListCampaignsClientMockRecorder) Context 

func (mr *MockCampaignService_ListCampaignsClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockCampaignService_ListCampaignsClientMockRecorder) Header 

func (mr *MockCampaignService_ListCampaignsClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockCampaignService_ListCampaignsClientMockRecorder) Recv 

func (mr *MockCampaignService_ListCampaignsClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockCampaignService_ListCampaignsClientMockRecorder) RecvMsg 

func (mr *MockCampaignService_ListCampaignsClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockCampaignService_ListCampaignsClientMockRecorder) SendMsg 

func (mr *MockCampaignService_ListCampaignsClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockCampaignService_ListCampaignsClientMockRecorder) Trailer 

func (mr *MockCampaignService_ListCampaignsClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockCampaignService_ListCampaignsServer 

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

MockCampaignService_ListCampaignsServer is a mock of CampaignService_ListCampaignsServer interface.

func NewMockCampaignService_ListCampaignsServer 

func NewMockCampaignService_ListCampaignsServer(ctrl *gomock.Controller) *MockCampaignService_ListCampaignsServer

NewMockCampaignService_ListCampaignsServer creates a new mock instance.

func (*MockCampaignService_ListCampaignsServer) Context 

func (m *MockCampaignService_ListCampaignsServer) Context() context.Context

Context mocks base method.

func (*MockCampaignService_ListCampaignsServer) EXPECT 

func (m *MockCampaignService_ListCampaignsServer) EXPECT() *MockCampaignService_ListCampaignsServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCampaignService_ListCampaignsServer) RecvMsg 

func (m *MockCampaignService_ListCampaignsServer) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockCampaignService_ListCampaignsServer) Send 

func (m *MockCampaignService_ListCampaignsServer) Send(arg0 *GetCampaignResponse) error

Send mocks base method.

func (*MockCampaignService_ListCampaignsServer) SendHeader 

func (m *MockCampaignService_ListCampaignsServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockCampaignService_ListCampaignsServer) SendMsg 

func (m *MockCampaignService_ListCampaignsServer) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockCampaignService_ListCampaignsServer) SetHeader 

func (m *MockCampaignService_ListCampaignsServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockCampaignService_ListCampaignsServer) SetTrailer 

func (m *MockCampaignService_ListCampaignsServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockCampaignService_ListCampaignsServerMockRecorder 

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

MockCampaignService_ListCampaignsServerMockRecorder is the mock recorder for MockCampaignService_ListCampaignsServer.

func (*MockCampaignService_ListCampaignsServerMockRecorder) Context 

func (mr *MockCampaignService_ListCampaignsServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockCampaignService_ListCampaignsServerMockRecorder) RecvMsg 

func (mr *MockCampaignService_ListCampaignsServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockCampaignService_ListCampaignsServerMockRecorder) Send 

func (mr *MockCampaignService_ListCampaignsServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockCampaignService_ListCampaignsServerMockRecorder) SendHeader 

func (mr *MockCampaignService_ListCampaignsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockCampaignService_ListCampaignsServerMockRecorder) SendMsg 

func (mr *MockCampaignService_ListCampaignsServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockCampaignService_ListCampaignsServerMockRecorder) SetHeader 

func (mr *MockCampaignService_ListCampaignsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockCampaignService_ListCampaignsServerMockRecorder) SetTrailer 

func (mr *MockCampaignService_ListCampaignsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockCampaignService_RunBacktestByCampaignClient 

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

MockCampaignService_RunBacktestByCampaignClient is a mock of CampaignService_RunBacktestByCampaignClient interface.

func NewMockCampaignService_RunBacktestByCampaignClient 

func NewMockCampaignService_RunBacktestByCampaignClient(ctrl *gomock.Controller) *MockCampaignService_RunBacktestByCampaignClient

NewMockCampaignService_RunBacktestByCampaignClient creates a new mock instance.

func (*MockCampaignService_RunBacktestByCampaignClient) CloseSend 

func (m *MockCampaignService_RunBacktestByCampaignClient) CloseSend() error

CloseSend mocks base method.

func (*MockCampaignService_RunBacktestByCampaignClient) Context 

func (m *MockCampaignService_RunBacktestByCampaignClient) Context() context.Context

Context mocks base method.

func (*MockCampaignService_RunBacktestByCampaignClient) EXPECT 

func (m *MockCampaignService_RunBacktestByCampaignClient) EXPECT() *MockCampaignService_RunBacktestByCampaignClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCampaignService_RunBacktestByCampaignClient) Header 

func (m *MockCampaignService_RunBacktestByCampaignClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockCampaignService_RunBacktestByCampaignClient) Recv 

func (m *MockCampaignService_RunBacktestByCampaignClient) Recv() (*BacktestResultResponse, error)

Recv mocks base method.

func (*MockCampaignService_RunBacktestByCampaignClient) RecvMsg 

func (m *MockCampaignService_RunBacktestByCampaignClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockCampaignService_RunBacktestByCampaignClient) SendMsg 

func (m *MockCampaignService_RunBacktestByCampaignClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockCampaignService_RunBacktestByCampaignClient) Trailer 

func (m *MockCampaignService_RunBacktestByCampaignClient) Trailer() metadata.MD

Trailer mocks base method.

type MockCampaignService_RunBacktestByCampaignClientMockRecorder 

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

MockCampaignService_RunBacktestByCampaignClientMockRecorder is the mock recorder for MockCampaignService_RunBacktestByCampaignClient.

func (*MockCampaignService_RunBacktestByCampaignClientMockRecorder) CloseSend 

func (mr *MockCampaignService_RunBacktestByCampaignClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockCampaignService_RunBacktestByCampaignClientMockRecorder) Context 

func (mr *MockCampaignService_RunBacktestByCampaignClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockCampaignService_RunBacktestByCampaignClientMockRecorder) Header 

func (mr *MockCampaignService_RunBacktestByCampaignClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockCampaignService_RunBacktestByCampaignClientMockRecorder) Recv 

func (mr *MockCampaignService_RunBacktestByCampaignClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockCampaignService_RunBacktestByCampaignClientMockRecorder) RecvMsg 

func (mr *MockCampaignService_RunBacktestByCampaignClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockCampaignService_RunBacktestByCampaignClientMockRecorder) SendMsg 

func (mr *MockCampaignService_RunBacktestByCampaignClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockCampaignService_RunBacktestByCampaignClientMockRecorder) Trailer 

func (mr *MockCampaignService_RunBacktestByCampaignClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockCampaignService_RunBacktestByCampaignServer 

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

MockCampaignService_RunBacktestByCampaignServer is a mock of CampaignService_RunBacktestByCampaignServer interface.

func NewMockCampaignService_RunBacktestByCampaignServer 

func NewMockCampaignService_RunBacktestByCampaignServer(ctrl *gomock.Controller) *MockCampaignService_RunBacktestByCampaignServer

NewMockCampaignService_RunBacktestByCampaignServer creates a new mock instance.

func (*MockCampaignService_RunBacktestByCampaignServer) Context 

func (m *MockCampaignService_RunBacktestByCampaignServer) Context() context.Context

Context mocks base method.

func (*MockCampaignService_RunBacktestByCampaignServer) EXPECT 

func (m *MockCampaignService_RunBacktestByCampaignServer) EXPECT() *MockCampaignService_RunBacktestByCampaignServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCampaignService_RunBacktestByCampaignServer) RecvMsg 

func (m *MockCampaignService_RunBacktestByCampaignServer) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockCampaignService_RunBacktestByCampaignServer) Send 

func (m *MockCampaignService_RunBacktestByCampaignServer) Send(arg0 *BacktestResultResponse) error

Send mocks base method.

func (*MockCampaignService_RunBacktestByCampaignServer) SendHeader 

func (m *MockCampaignService_RunBacktestByCampaignServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockCampaignService_RunBacktestByCampaignServer) SendMsg 

func (m *MockCampaignService_RunBacktestByCampaignServer) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockCampaignService_RunBacktestByCampaignServer) SetHeader 

func (m *MockCampaignService_RunBacktestByCampaignServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockCampaignService_RunBacktestByCampaignServer) SetTrailer 

func (m *MockCampaignService_RunBacktestByCampaignServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockCampaignService_RunBacktestByCampaignServerMockRecorder 

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

MockCampaignService_RunBacktestByCampaignServerMockRecorder is the mock recorder for MockCampaignService_RunBacktestByCampaignServer.

func (*MockCampaignService_RunBacktestByCampaignServerMockRecorder) Context 

func (mr *MockCampaignService_RunBacktestByCampaignServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockCampaignService_RunBacktestByCampaignServerMockRecorder) RecvMsg 

func (mr *MockCampaignService_RunBacktestByCampaignServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockCampaignService_RunBacktestByCampaignServerMockRecorder) Send 

func (mr *MockCampaignService_RunBacktestByCampaignServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockCampaignService_RunBacktestByCampaignServerMockRecorder) SendHeader 

func (mr *MockCampaignService_RunBacktestByCampaignServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockCampaignService_RunBacktestByCampaignServerMockRecorder) SendMsg 

func (mr *MockCampaignService_RunBacktestByCampaignServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockCampaignService_RunBacktestByCampaignServerMockRecorder) SetHeader 

func (mr *MockCampaignService_RunBacktestByCampaignServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockCampaignService_RunBacktestByCampaignServerMockRecorder) SetTrailer 

func (mr *MockCampaignService_RunBacktestByCampaignServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type StartCampaignRequest 

type StartCampaignRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

StartCampaignRequest is the request for start campaign

func (*StartCampaignRequest) Descriptor deprecated 

func (*StartCampaignRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartCampaignRequest.ProtoReflect.Descriptor instead.

func (*StartCampaignRequest) GetId 

func (x *StartCampaignRequest) GetId() string

func (*StartCampaignRequest) ProtoMessage 

func (*StartCampaignRequest) ProtoMessage()

func (*StartCampaignRequest) ProtoReflect 

func (x *StartCampaignRequest) ProtoReflect() protoreflect.Message

func (*StartCampaignRequest) Reset 

func (x *StartCampaignRequest) Reset()

func (*StartCampaignRequest) String 

func (x *StartCampaignRequest) String() string

type StartCampaignResponse 

type StartCampaignResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

StartCampaignResponse is the response for start campaign

func (*StartCampaignResponse) Descriptor deprecated 

func (*StartCampaignResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartCampaignResponse.ProtoReflect.Descriptor instead.

func (*StartCampaignResponse) GetId 

func (x *StartCampaignResponse) GetId() string

func (*StartCampaignResponse) ProtoMessage 

func (*StartCampaignResponse) ProtoMessage()

func (*StartCampaignResponse) ProtoReflect 

func (x *StartCampaignResponse) ProtoReflect() protoreflect.Message

func (*StartCampaignResponse) Reset 

func (x *StartCampaignResponse) Reset()

func (*StartCampaignResponse) String 

func (x *StartCampaignResponse) String() string

type UnimplementedCampaignServiceServer 

type UnimplementedCampaignServiceServer struct{}

UnimplementedCampaignServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedCampaignServiceServer) CreateCampaign 

func (UnimplementedCampaignServiceServer) CreateCampaign(context.Context, *CreateCampaignRequest) (*CreateCampaignResponse, error)

func (UnimplementedCampaignServiceServer) GetCampaign 

func (UnimplementedCampaignServiceServer) GetCampaign(context.Context, *GetCampaignRequest) (*GetCampaignResponse, error)

func (UnimplementedCampaignServiceServer) ListCampaigns 

func (UnimplementedCampaignServiceServer) ListCampaigns(*ListCampaignsRequest, grpc.ServerStreamingServer[GetCampaignResponse]) error

func (UnimplementedCampaignServiceServer) RunBacktestByCampaign 

func (UnimplementedCampaignServiceServer) RunBacktestByCampaign(*GetCampaignRequest, grpc.ServerStreamingServer[BacktestResultResponse]) error

func (UnimplementedCampaignServiceServer) StartCampaign 

func (UnimplementedCampaignServiceServer) StartCampaign(context.Context, *StartCampaignRequest) (*StartCampaignResponse, error)

type UnsafeCampaignServiceServer 

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

UnsafeCampaignServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CampaignServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.