Function TestPartialBatchCodec_Encode

codecs/partial_codecs_test.go:421–542

(t *testing.T)

}

func TestPartialBatchCodec_Encode(t *testing.T) {
	tests := []struct {
		name string
		msg  *message.Batch
	}{
		{
			name: "simple",
			msg: &message.Batch{
				Type: primitive.BatchTypeLogged,
				Children: []*message.BatchChild{
					{Query: "select * from table1"},
					{Id: []byte{0x1, 0x2, 0x3, 0x4, 0x5, 0x6, 0x7, 0x8}},
				},
			},
		},
		{
			name: "positional values",
			msg: &message.Batch{
				Type: primitive.BatchTypeLogged,
				Children: []*message.BatchChild{
					{
						Query: "select * from table1",
						Values: []*primitive.Value{
							{
								Type:     primitive.ValueTypeRegular,
								Contents: []byte{0x1, 0x2, 0x3},
							},
							{
								Type:     primitive.ValueTypeRegular,
								Contents: []byte{0x4, 0x5, 0x6},
							},
						},
					},
					{
						Id: []byte{0x1, 0x2, 0x3, 0x4, 0x5, 0x6, 0x7, 0x8},
						Values: []*primitive.Value{
							{
								Type:     primitive.ValueTypeRegular,
								Contents: []byte{0x1, 0x2, 0x3},
							},
							{
								Type:     primitive.ValueTypeRegular,
								Contents: []byte{0x4, 0x5, 0x6},
							},
						},
					},
				},
			},
		},
		{
			name: "consistency",
			msg: &message.Batch{
				Type: primitive.BatchTypeLogged,
				Children: []*message.BatchChild{
					{Query: "select * from table1"},
					{Id: []byte{0x1, 0x2, 0x3, 0x4, 0x5, 0x6, 0x7, 0x8}},
				},
				Consistency: primitive.ConsistencyLevelEachQuorum,